 /**
 * 上海中赢金融信息服务有限公司
 * Copyright (c) 2017-2027 Chinazyjr,Inc.All Rights Reserved.
 */
package com.sys.kafka.config;
/**
 * 
 * <b>Description：</b> kafka 配置信息  <br/>
 * <b>ClassName：</b> KafkaConfigKey <br/>
 * <b>@author：</b> jackyshang <br/>
 * <b>@date：</b> 2016年7月15日 上午11:54:53 <br/>
 * <b>@version: </b>  <br/>
 */
public class KafkaConfigKey {
    
    public static final String KEY_BOOTSTRAP_SERVERS = "bootstrap.servers";
    
    //producer 参数配置
    public static final String KEY_PRODUCER_BATCH_SIZE = "producer.batch.size";
    public static final String KEY_PRODUCER_RETRIES = "producer.retries";
    public static final String KEY_PRODUCER_ACKS = "producer.acks";
    public static final String KEY_PRODUCER_LINGER_MS = "producer.linger.ms";
    public static final String KEY_PRODUCER_BUFFER_MEMORY = "producer.buffer.memory";
    public static final String KEY_PRODUCER_BLOCK_ON_BUFFER_FULL = "producer.block.on.buffer.full";
    public static final String KEY_PRODUCER_TIMEOUT_MS = "producer.timeout.ms";
    public static final String KEY_PRODUCER_RECONNECT_BACKOFF_MS = "producer.reconnect.backoff.ms";
    public static final String KEY_PRODUCER_KEY_SERIALIZER = "producer.key.serializer";
    public static final String KEY_PRODUCER_VALUE_SERIALIZER = "producer.value.serializer";
    
    //consumer 参数配置
    public static final String KEY_CONSUMER_GROUP_ID = "consumer.group.id";
    public static final String KEY_CONSUMER_ENABLE_AUTO_COMMIT = "consumer.enable.auto.commit";
    public static final String KEY_CONSUMER_AUTO_COMMIT_INTERVAL_MS = "consumer.auto.commit.interval.ms";
    public static final String KEY_CONSUMER_SESSION_TIMEOUT_MS = "consumer.session.timeout.ms";
    public static final String KEY_CONSUMER_KEY_SERIALIZER = "consumer.key.serializer";
    public static final String KEY_CONSUMER_VALUE_SERIALIZER = "consumer.value.serializer";
    public static final String KEY_CONSUMER_AUTO_OFFSET_RESET = "consumer.auto.offset.reset";
}

